package baseFx.common.mq;

import java.util.Arrays;
import java.util.List;

public interface MqPublisher extends AutoCloseable {
    @Override
    void close();

    void post(String queue, List<String> msg);

    default void post(String queue, String msg) {
        post(queue, Arrays.asList(msg));
    }

    default void beginTransaction() {

    }

    default void commit() {

    }

    default void rollback() {

    }
}
